bootstrap = {
  xds_servers: [
    {
      server_uri: "xds-control-plane:18000",
      channel_creds: [{ type: "insecure" }]
    }
  ],
  node: {
    id: "test-client-#{Process.pid}",
    cluster: "test"
  }
}

client = Async::GRPC::XDS::Client.new("myservice", bootstrap: bootstrap)

stub = client.stub(Async::GRPC::Fixtures::TestInterface, "myservice")

request = Protocol::GRPC::Fixtures::TestMessage.new(value: "hello")
response = stub.unary_call(request)
puts response.value

endpoint = Async::HTTP::Endpoint.parse(
  "http://localhost:50051",
  protocol: Async::HTTP::Protocol::HTTP2
)

http_client = Async::HTTP::Client.new(endpoint)
client = Async::GRPC::Client.new(http_client)

stub = client.stub(Async::GRPC::Fixtures::TestInterface, "myservice")

request = Protocol::GRPC::Fixtures::TestMessage.new(value: "hello")
response = stub.unary_call(request)
puts response.value